package com.qudian.pay.mq.producer;

import com.qudian.pay.mq.SendMessage;
import com.alibaba.rocketmq.client.producer.SendCallback;
import com.qudian.pay.mq.DefaultSendResult;

/**
 * @Description: MQ生产者接口
 * @author gaoxiang
 * @date 2017年2月6日 下午6:13:56
 */ 
public interface MQProducer {
	
	/**
	 * @Description: 同步发送消息服务
	 * @author gaoxiang
	 * @date 2016年5月23日 下午1:22:49
	 */
	DefaultSendResult sendMessage(String topic, String tag, SendMessage msg);
	
	/**
	 * @Description: 异步发送消息服务
	 * @author gaoxiang
	 * @date 2016年5月23日 下午1:22:49
	 */
	void sendMessage(String topic, String tag, SendMessage msg,SendCallback sendCallback);
}
